package com.opensky.sys.interfaces.assembler;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.opensky.common.infrastructure.util.DataBeanUtil;
import com.opensky.common.interfaces.frm.CommonIdFrm;
import com.opensky.common.interfaces.frm.CommonIdsFrm;
import com.opensky.common.interfaces.vo.PageVO;
import com.opensky.sys.application.service.MybatisPlusExampleService;
import com.opensky.sys.domain.mybatis.entity.MybatisPlusExampleEntity;
import com.opensky.sys.interfaces.frm.ExampleQueryFrm;
import com.opensky.sys.interfaces.frm.ExampleSaveFrm;
import com.opensky.sys.interfaces.vo.ExampleVO;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * description Mybatis示例Assembler
 *
 * @author ZY
 * @date 2021年05月15日 11:23
 */
@Component
public class MybatisPlusExampleAssembler {

    /**
     * 注入service
     */
    @Resource
    private MybatisPlusExampleService service;

    /**
     * 新增数据
     *
     * @param frm 参数对象
     * @return 视图对象
     */
    public ExampleVO insert(ExampleSaveFrm frm) {
        MybatisPlusExampleEntity entity = convertFromFrm(frm);
        entity.setCreateTime(new Date());
        entity.setUpdateTime(new Date());
        boolean result = service.insert(entity);
        if (result) {
            return convertToVO(entity);
        }
        return null;
    }

    /**
     * 删除对象
     *
     * @param frm 参数对象
     * @return true:删除成功 false:删除失败
     */
    public Integer delete(CommonIdFrm frm) {
        boolean result = service.deleteById(frm.getId());
        if (result) {
            return 1;
        }
        return 0;
    }

    /**
     * 更新对象
     *
     * @param frm 待更新的Frm对象
     * @return 成功返回更新后的VO对象，失败返回null
     */
    public ExampleVO update(ExampleSaveFrm frm) {
        MybatisPlusExampleEntity entity = convertFromFrm(frm);
        entity.setUpdateTime(new Date());
        boolean result = service.updateById(entity);
        if (result) {
            return convertToVO(entity);
        }
        return null;
    }

    /**
     * 根据ID查询数据
     *
     * @param frm 主键Frm对象
     * @return 成功返回对应ID的VO对象，失败返回null
     */
    public ExampleVO findById(CommonIdFrm frm) {
        return convertToVO(service.selectById(frm.getId()));
    }

    /**
     * 通过主键批量查询数据集合
     *
     * @param frm 主键集合Frm对象
     * @return 成功返回对应ID集合的VO对象集合，失败返回空集合
     */
     public List<ExampleVO> findByIds(CommonIdsFrm frm) {
        List<ExampleVO> retList = new ArrayList<>();
        if (CollectionUtils.isEmpty(frm.getIds())) {
            return retList;
        }
        List<MybatisPlusExampleEntity> list = service.selectBatchIds(frm.getIds());
        if (!CollectionUtils.isEmpty(list)) {
            list.forEach(x -> retList.add(convertToVO(x)));
        }
        return retList;
     }

    /**
     * 根据条件查询数据集合
     *
     * @param frm 查询条件对象
     * @return 满足条件的数据集合
     */
    public List<ExampleVO> getList(ExampleQueryFrm frm) {
        List<ExampleVO> retList = new ArrayList<>();
        Wrapper<MybatisPlusExampleEntity> wrapper = new EntityWrapper<MybatisPlusExampleEntity>()
                .eq("id", frm.getId())
                .like("name", frm.getName() + "%");
        List<MybatisPlusExampleEntity> list = service.selectList(wrapper);
        if (!CollectionUtils.isEmpty(list)) {
            list.forEach(x -> retList.add(convertToVO(x)));
            return retList;
        }
        return retList;
    }

    /**
     * 根据条件查询分页
     *
     * @param frm 查询条件
     * @return 满足条件的分页
     */
    public PageVO<ExampleVO> getPageInfo(ExampleQueryFrm frm) {
        Page<MybatisPlusExampleEntity> pageParam = new Page<>(frm.getPageNum(), frm.getPageSize());
        Wrapper<MybatisPlusExampleEntity> wrapper = new EntityWrapper<MybatisPlusExampleEntity>()
                .eq("id", frm.getId())
                .like("name", frm.getName() + "%");
        Page<MybatisPlusExampleEntity> page = service.selectPage(pageParam,wrapper);
        System.out.println(JSON.toJSONString(page));
        return new PageVO<>();
    }

    /**
     * Frm 转 实体类
     *
     * @param frm 参数对象
     * @return 返回转换后的实体对象
     */
    public static MybatisPlusExampleEntity convertFromFrm(ExampleSaveFrm frm) {
        return DataBeanUtil.copyOf(frm, MybatisPlusExampleEntity.class, true);
    }

    /**
     * 实体类 转 VO
     *
     * @param entity 实体类对象
     * @return 返回转化后的VO对象
     */
    public static ExampleVO convertToVO(MybatisPlusExampleEntity entity) {
        if (entity == null) {
            return null;
        }
        return DataBeanUtil.copyOf(entity, ExampleVO.class, true);
    }

}
